package com.meta.api.flink;

import org.springframework.stereotype.Component;

import com.meta.api.param.UserParam;

/**
 * @Author: xieZW
 * @Date: 2023/2/24 15:21
 */
@Component
public class FlinkService {

//    static ArrayList<String> list = new ArrayList<>();
//
//    static {
//        for (int i = 0; i < 10000; i++) {
//            list.add("这是" + i + "构造的字符串！");
//        }
//
//    }


    public Object excuteFlinkJob(UserParam param) {

//        ExecutionEnvironment fsEnv = ExecutionEnvironment.getExecutionEnvironment();
//
//        List<Row> list = new ArrayList<>();
//        for (int i = 0; i < 10000; i++) {
//            Row row = new Row(1);
//            row.setField(0, "这是" + i + "构造的字符串！");
//            list.add(row);
//        }
//        DataSource<Row> source = fsEnv.fromCollection(list);
//
//        BatchTableEnvironment fbTableEnv = BatchTableEnvironment.create(fsEnv);
//
//        fbTableEnv.createTemporaryView("table", source, "key,value");
//
//        Table result = fbTableEnv.sqlQuery("sql");
//
        return null;
    }


    public static void main(String[] args) {

//        ExecutionEnvironment fsEnv = ExecutionEnvironment.getExecutionEnvironment();
//
//        List<Row> list = new ArrayList<>();
//        for (int i = 0; i < 10000; i++) {
//            Row row = new Row(1);
//            row.setField(0, "这是" + i + "构造的字符串！");
//            list.add(row);
//        }
//        DataSource<Row> source = fsEnv.fromCollection(list);
//
//        BatchTableEnvironment fbTableEnv = BatchTableEnvironment.create(fsEnv);
//
//        fbTableEnv.createTemporaryView("table", source, "key,value");
//
//        Table result = fbTableEnv.sqlQuery("sql");


    }
}
